package com.aabbc.webflux.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;

import java.time.Instant;

/**
 * WebfluxController
 *
 * @author: <a href="mailto:chenfenghai@oristartech.com">chenfenghai</a>
 * @version: 1.0
 * @date: 2019-12-02 17:25
 */
@RestController
public class WebfluxController {

    @GetMapping("/test")
    public Flux<String> test(){
        return Flux.just("WebfluxController.test", String.valueOf(Instant.now().toEpochMilli()));
    }
}
